package wanda.topologies.bases

import org.apache.spark.sql.{Dataset, SparkSession}

import scala.collection.mutable

trait SparkStreamingTopology extends SparkTopology{

  def process (DStream:Dataset[mutable.Map[String, String]])




}
